package com.ffcs.crmd.tsp.core.netty.server;

import com.ffcs.crmd.tsp.api.dto.netty.RemotingCommand;
import com.ffcs.crmd.tsp.api.netty.INettyRemotingServer;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * 
 * 功能说明:处理客户端发送过来的请求
 *
 * @author ZHONGFUHUA
 * 
 * @Date 2016年1月24日 下午9:54:35
 *
 *
 * 版本号  |   作者   |  修改时间   |   修改内容
 *
 */
public class NettyServerHandler extends SimpleChannelInboundHandler<RemotingCommand> {
    /**
     * 通信客户端
     */
    private INettyRemotingServer remotingServer;
    
    public NettyServerHandler(INettyRemotingServer remotingServer) {
        this.remotingServer = remotingServer;
    }
    
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, RemotingCommand msg) throws Exception {
        remotingServer.processMessageReceived(ctx, msg);
    }
    
}
